package com.deep.flink.demo.function;


import org.apache.flink.table.functions.AggregateFunction;


/**
 * （1）org.apache.flink.api.common.functions.AggregateFunction
 * 在window流之后，做窗口内的统计计算
 * （2）org.apache.flink.table.functions.AggregateFunction
 * 可以理解为flink中的一个算子，和MapFunction、FlatMapFunction等是同级别的，
 * 而抽象类AggregateFunction是用于用户自定义聚合函数的，和max、min之类的函数是同级的
 */
public class AggFunction extends AggregateFunction<Long, Long> {

    @Override
    public Long createAccumulator() {
        return 0L;
    }


    @Override
    public Long getValue(Long aLong) {
        return 100L;
    }

    public void accumulate(long iValue) {

    }
}
